package com.huwaiwai.kafka.demo01;

import com.huwaiwai.kafka.KafkaProperties;
import com.huwaiwai.kafka.demo01.consumer.KafkaConsumer;
import com.huwaiwai.kafka.demo01.producer.KafkaProducer;

/**
 * 测试
 * Created by Administrator on 2017/4/29.
 */
public class Test {

    public static void main(String [] args) {
        KafkaProducer producer = new KafkaProducer(KafkaProperties.TOPIC);
        producer.start();

        KafkaConsumer consumer = new KafkaConsumer(KafkaProperties.TOPIC);
        consumer.start();

    }

}
